package com.jeffse.light.stream.core.function.base;

import com.jeffse.light.stream.core.data.context.SourceContext;

public interface SourceFunction<P> extends Function {

    void run(SourceContext<P> ctx) throws Exception;

}
